package com.vodafone.mapreduce.processor;

import org.corf.endpoint.collector.Collector;
import org.corf.endpoint.emitter.Emitter;
import org.corf.payload.Payload;
import org.corf.processor.DefaultProcessor;

import com.vodafone.mapreduce.divide.DivideFunction;

public class DivideInputDtoProcessor extends DefaultProcessor {

    private DivideFunction f;

    protected DivideInputDtoProcessor(String name, Collector collector, Emitter emitter) {
        super(name, collector, emitter);
    }

    @Override
    public void process(Payload p) {
        // TODO Auto-generated method stub

    }

}
